package PrjDBUtils

import (
	db_utils "dgo/goutils/db-utils"
)

var (
	// Db_exec_queue *utils.QueueTask = utils.NewQueueTaskFunc()
	defaultDbExecQueue *DBQueueTask = NewDBQueueTask()
)

func PushDBExecQueue(cb func(db *db_utils.DBConn, rec *Db_exec_rec) error) {
	defaultDbExecQueue.PushDBExecQueue(cb)
}

func StartDBExecQueueService(dbid string) {
	defaultDbExecQueue.StartDBExecQueueService(dbid)
}
